A Java 8 Streams Cookbook

Streams in Java 8 provide a declarative approach to Collections. The simplest analogy is that your Collection is a water barrel, and when you turn the tap (faucet), you create a stream, which you can then process.

The advantages of Streams are:

• Declarative
• Parallelizable
• Reduced boilerplate – internal iteration

The Stream operations are either:

• Intermediate – return streams
• Terminal – produce results

The final point is that streams can only be traversed once.

Cookbook

import java.time.Duration;
import java.util.*;

import static java.util.stream.Collectors.toList;
import static java.util.stream.Collectors.*;

public class Winner {

 private int year;
 private String nationality;
 private String name;
 private String team;
 private int lengthKm;
 private Duration winningTime;
 private int stageWins;
 private int daysInYellow;

 public Winner(int year, String nationality, String name, String team, int lengthKm, Duration winningTime, int daysInYellow) {
 this.year = year;
 this.nationality = nationality;
 this.name = name;
 this.team = team;
 this.lengthKm = lengthKm;
 this.winningTime = winningTime;
 this.daysInYellow = daysInYellow;
 }

 public static final List<Winner> tdfWinners = Arrays.asList(
 new Winner(2006, "Spain", "Óscar Pereiro", "Caisse d'Epargne–Illes Balears", 3657, Duration.parse("PT89H40M27S"), 8),
 new Winner(2007, "Spain", "Alberto Contador", "Discovery Channel", 3570, Duration.parse("PT91H00M26S"), 4),
 new Winner(2008, "Spain", "Carlos Sastre", "Team CSC", 3559, Duration.parse("PT87H52M52S"), 5),
 new Winner(2009, "Spain", "Alberto Contador", "Astana", 3459, Duration.parse("PT85H48M35S"), 7),
 new Winner(2010, "Luxembourg", "Andy Schleck", "Team Saxo Bank", 3642, Duration.parse("PT91H59M27S"), 12),
 new Winner(2011, "Australia", "Cadel Evans", "BMC Racing Team", 3430, Duration.parse("PT86H12M22S"), 2),
 new Winner(2012, "Great Britain", "Bradley Wiggins", "Team Sky", 3496, Duration.parse("PT87H34M47S"), 14),
 new Winner(2013, "Great Britain", "Chris Froome", "Team Sky", 3404, Duration.parse("PT83H56M20S"), 14),
 new Winner(2014, "Italy", "Vincenzo Nibali", "Astana", 3661, Duration.parse("PT89H59M06S"), 19),
 new Winner(2015, "Great Britain", "Chris Froome", "Team Sky", 3360, Duration.parse("PT84H46M14S"), 16),
 new Winner(2016, "Great Britain", "Chris Froome", "Team Sky", 3529, Duration.parse("PT89H04M48S"), 14 ));

 public static void main(String args[]) {

 // Filter and Map -
 List<String> winnersOfToursLessThan3500km = tdfWinners
 .stream()
 .filter(d -> d.getLengthKm() < 3500) // Separate out Tours less than 3500km
 .map(Winner::getName) // Get names of winners
 .collect(toList()); // Return a list
 // Winners of Tours Less than 3500km - [Alberto Contador, Cadel Evans, Bradley Wiggins, Chris Froome, Chris Froome] 
 System.out.println("Winners of Tours Less than 3500km - " + winnersOfToursLessThan3500km);


 List<String> winnersOfToursGreaterThan3500km = tdfWinners
 .stream()
 .filter(d -> d.getLengthKm() >= 3500)
 .map(Winner::getName)
 .collect(toList());
 // Winners of Tours Greater than 3500km - [Óscar Pereiro, Alberto Contador, Carlos Sastre, Andy Schleck, Vincenzo Nibali, Chris Froome]
 System.out.println("Winners of Tours Greater than 3500km - " + winnersOfToursGreaterThan3500km);


 // limit - 
 List<Winner> winnerObjectsOfToursLessThan3500kmLimit2 = tdfWinners
 .stream()
 .filter(d -> d.getLengthKm() < 3500)
 .limit(2)
 .collect(toList());
 // winnerObjectsOfToursLessThan3500kmLimit2 [Alberto Contador, Cadel Evans]
 System.out.println("winnerObjectsOfToursLessThan3500kmLimit2 " + winnerObjectsOfToursLessThan3500kmLimit2);


 List<String> firstTwoWinnersOfToursLessThan3500km = tdfWinners
 .stream()
 .filter(d -> d.getLengthKm() < 3500)
 .map(Winner::getName)
 .limit(2)
 .collect(toList());
 // firstTwoWinnersOfToursLessThan3500km - [Alberto Contador, Cadel Evans]
 System.out.println("firstTwoWinnersOfToursLessThan3500km - " + firstTwoWinnersOfToursLessThan3500km);

 // filter by distinct
 List<String> distinctTDFWinners = tdfWinners
 .stream()
 .map(Winner::getName)
 .distinct()
 .collect(toList());
 System.out.println("distinctTDFWinners - " + distinctTDFWinners);


 long numberOfDistinceWinners = tdfWinners
 .stream()
 .map(Winner::getName)
 .distinct()
 .count();
 // numberOfDistinceWinners - 8
 System.out.println("numberOfDistinceWinners - " + numberOfDistinceWinners);

 // skip records
 List<Winner> skipEveryOtherTDFWinner = tdfWinners
 .stream()
 .skip(2)
 .collect(toList());
 // skipEveryOtherTDFWinner - [Carlos Sastre, Alberto Contador, Andy Schleck, Cadel Evans, Bradley Wiggins, Chris Froome, Vincenzo Nibali, Chris Froome, Chris Froome]
 System.out.println("skipEveryOtherTDFWinner - " + skipEveryOtherTDFWinner);


 List<String> mapWinnerYearNamesToList = tdfWinners
 .stream()
 .map(w -> w.getYear() + " - " + w.getName())
 .collect(toList());
 // mapWinnerYearNamesToList [2006 - Óscar Pereiro, 2007 - Alberto Contador, 2008 - Carlos Sastre, 2009 - Alberto Contador, 2010 - Andy Schleck, 2011 - Cadel Evans, 2012 - Bradley Wiggins, 2013 - Chris Froome, 2014 - Vincenzo Nibali, 2015 - Chris Froome, 2016 - Chris Froome]
 System.out.println("mapWinnerYearNamesToList " + mapWinnerYearNamesToList);


 List<Integer> mapWinnerNameLengthToList = tdfWinners
 .stream()
 .map(Winner::getName)
 .map(String::length)
 .collect(toList());
 // mapWinnerNameLengthToList [13, 16, 13, 16, 12, 11, 15, 12, 15, 12, 12]
 System.out.println("mapWinnerNameLengthToList " + mapWinnerNameLengthToList);


 // matching - allMatch, noneMatch
 Optional<Winner> winner2012 = tdfWinners.stream().filter(w -> w.getName().contains("Wiggins")).findAny();
 // winner2012 - Bradley Wiggins
 System.out.println("winner2012 - " + winner2012.get());


 Optional<Integer> winnerYear2014 = tdfWinners.stream().map(Winner::getYear).filter(x -> x == 2014).findFirst();
 // winnerYear2014 - 2014
 System.out.println("winnerYear2014 - " + winnerYear2014.get());


 // reducing - 0 --> initial value
 int totalDistance = tdfWinners.stream().map(Winner::getLengthKm).reduce(0, Integer::sum);
 // totalDistance - 38767
 System.out.println("totalDistance - " + totalDistance);


 Optional<Integer> shortestYear = tdfWinners.stream().map(Winner::getLengthKm).reduce(Integer::min);
 // shortestYear - 3360
 System.out.println("shortestYear - " + shortestYear.get());


 Optional<Integer> longestYear = tdfWinners.stream().map(Winner::getLengthKm).reduce(Integer::max);
 // longestYear - 3661
 System.out.println("longestYear - " + longestYear.get());

 Optional<Winner> fastestWinner = tdfWinners.stream().min(Comparator.comparingDouble(Winner::getAveSpeed));
 System.out.println("fastestTDF - " + fastestWinner.get()); 

 // shorthand
 OptionalDouble fastestTDF = tdfWinners.stream().mapToDouble(Winner::getAveSpeed).min();
 // fastestTDF - 39.0
 System.out.println("fastestTDF - " + fastestTDF.getAsDouble());


 // groupingby - make a map whose keys are names
 Map<String, List<Winner>> namesVsWinner = tdfWinners.stream().collect(groupingBy(Winner::getName));
 // namesVsWinner - {Bradley Wiggins=[Bradley Wiggins], Carlos Sastre=[Carlos Sastre], Cadel Evans=[Cadel Evans], Óscar Pereiro=[Óscar Pereiro], Chris Froome=[Chris Froome, Chris Froome, Chris Froome], Andy Schleck=[Andy Schleck], Alberto Contador=[Alberto Contador, Alberto Contador], Vincenzo Nibali=[Vincenzo Nibali]}
 System.out.println("namesVsWinner - " + namesVsWinner);

 // join strings
 String allTDFWinnersTeamsCSV = tdfWinners.stream().map(Winner::getTeam).collect(joining(", "));
 // allTDFWinnersTeams Caisse d'Epargne–Illes Balears, Discovery Channel, Team CSC, Astana, Team Saxo Bank, BMC Racing Team, Team Sky, Team Sky, Astana, Team Sky, Team Sky
 System.out.println("allTDFWinnersTeams " + allTDFWinnersTeamsCSV);

 // grouping
 Map<String, List<Winner>> winnersByNationality = tdfWinners.stream().collect(groupingBy(Winner::getNationality));
 // winnersByNationality - {Great Britain=[Bradley Wiggins, Chris Froome, Chris Froome, Chris Froome], Luxembourg=[Andy Schleck], Italy=[Vincenzo Nibali], Australia=[Cadel Evans], Spain=[Óscar Pereiro, Alberto Contador, Carlos Sastre, Alberto Contador]}
 System.out.println("winnersByNationality - " + winnersByNationality);

 Map<String, Long> winsByNationalityCounting = tdfWinners.stream().collect(groupingBy(Winner::getNationality, counting()));
 // winsByNationalityCounting - {Great Britain=4, Luxembourg=1, Italy=1, Australia=1, Spain=4}
 System.out.println("winsByNationalityCounting - " + winsByNationalityCounting);

 }

 public double getAveSpeed() { 
 return (getLengthKm() / (getWinningTime().getSeconds() / 3600) );
 }

 public int getYear() {
 return year;
 }

 public void setYear(int year) {
 this.year = year;
 }

 public String getNationality() {
 return nationality;
 }

 public void setNationality(String nationality) {
 this.nationality = nationality;
 }

 public String getName() {
 return name;
 }

 public void setName(String name) {
 this.name = name;
 }

 public String getTeam() {
 return team;
 }

 public void setTeam(String team) {
 this.team = team;
 }

 public int getLengthKm() {
 return lengthKm;
 }

 public void setLengthKm(int lengthKm) {
 this.lengthKm = lengthKm;
 }

 public Duration getWinningTime() {
 return winningTime;
 }

 public void setWinningTime(Duration winningTime) {
 this.winningTime = winningTime;
 }

 public int getStageWins() {
 return stageWins;
 }

 public void setStageWins(int stageWins) {
 this.stageWins = stageWins;
 }

 public int getDaysInYellow() {
 return daysInYellow;
 }

 public void setDaysInYellow(int daysInYellow) {
 this.daysInYellow = daysInYellow;
 }

 @Override
 public String toString() {
 return name;
 } 

}

If you enjoyed this article and want to learn more about Java Streams, check out this collection of tutorials and articles on all things Java Streams.